package com.example.rocketstream.temp.stream;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author aliceblue
 * @date 20/2/19 17:37
 */
public interface StreamInput {

    String SMS_INPUT = "SMSInput";

    String ANT_INPUT = "ANTInput";

    @Input
    SubscribableChannel SMSInput();

    @Input
    SubscribableChannel ANTInput();
}
